package com.zxq.frame.iec104.rabbitmq;


import com.zxq.frame.core.ExchangeDTO;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;


@Component
@Slf4j
public class RabbitSubscribeHelper {


    /**
     * 通知web层
     * @param exchangeDTO 交换数据
     * @throws Exception
     */
    @RabbitListener(queues = "${spring.rabbitmq.template.network-queue}")
    public void receiveWeb(ExchangeDTO exchangeDTO) throws Exception {

    }


    /**
     * 通知network层
     * @param exchangeDTO 交换数据
     * @throws Exception
     */
    @RabbitListener(queues = "${spring.rabbitmq.template.web-queue}")
    public void receiveNetwork(ExchangeDTO exchangeDTO) throws Exception {


    }



}
